package org.sean.framework.kafka.producer;

import org.sean.framework.kafka.message.UniqueMessage;
import org.springframework.kafka.core.KafkaTemplate;

/**
 * Kafka 生产者
 *
 * @param <V> V
 */
public class KafkaUniqueProducer<V> extends BaseProducer<V> {


    public KafkaUniqueProducer(KafkaTemplate<Object, Object> template) {
        super(template);
    }

    @Override
    String convertMessage(V message) {
        return new UniqueMessage<>(message).toString();
    }
}
